package com.yytek.common.client.base;

public interface IMqClient {
	boolean open();
	boolean subscribe(String topic);
	boolean unsubscribe(String topic);
	void close();
	boolean isConnected();
	void setMessageCallBack(MessageCallBack messageCallBack);
	boolean publish(String topic, String content, int qos, int timout);
	boolean publish(String topic, String content);
	boolean publish(String topic, MqMessage content);
	
}
